package org.example;

import org.example.model.TableLineage;

public class MysqlCdcFinkConnectorOptionParser implements FinkConnectorOptionParser {


    @Override
    public String getTableName(TableLineage tableLineage) {
        return tableLineage.getOptions().get("table-name");
    }

    @Override
    public String getDatabaseName(TableLineage tableLineage) {
        return tableLineage.getOptions().get("database-name");
    }

    @Override
    public String getDataBaseType(TableLineage tableLineage) {
        return "mysql";
    }
}
